# encoding: UTF-8
# 引擎方法
import zmq  # netMQ
import gzip  # 解压
import json
import time
from py_at.Enums import *
import datetime
# a=time.time()
# context = zmq.Context()
# socket = context.socket(zmq.REQ)  # REQ模式,即REQ-RSP  CS结构
# socket.connect('tcp://58.247.171.146:5055')  # 实际netMQ数据服务器地址
# # 请求数据格式
# req = ReqPackage()
# req.Type = 0  # BarType.Min ????      0 得到历史数据1min   1得到日线数据   2 得到当日数据  3交易时段（是否有夜盘 是否在交易  是否已经收盘等）   4期货合约数据 最小跳最小量等   5应该是一年的交易日    6所有合约的代码
# req.Instrument = 'rb1801'
# req.Begin =(datetime.datetime.now()-datetime.timedelta(days = 10)).strftime("%Y%m%d")
# req.End = (datetime.datetime.now()-datetime.timedelta(days = 1)).strftime("%Y%m%d")
# # __dict__返回diction格式,即{key,value}格式
# p = req.__dict__
# socket.send_json(p)  # 直接发送__dict__转换的{}即可,不需要再转换成str
#
# # msg = socket.recv_unicode()	#服务器此处查询出现异常, 排除中->C#正常
# # 用recv接收,但是默认的socket中并没有此提示函数(可能是向下兼容的函数),不知能否转换为其他格式
# bs = socket.recv()  # 此处得到的是bytes
#
# # gzip解压:decompress(bytes)解压,会得到解压后的bytes,再用decode转成string
# gzipper = gzip.decompress(bs).decode()  # decode转换为string
#
# # json解析:与dumps对应,将str转换为{}
# bars = json.loads(gzipper)  # json解析
#
# # 此处对bars进行数据组合,即1min->nmin
# for bar in bars:
#     print(bar)
# print(time.time()-a)
#

def jy(name,price,minprice):
    if price % minprice != 0:
        if (name == "Buy"):price = price + (minprice - (price % minprice))
        elif (name == "Sell"):price = price - (price % minprice)
        print(price)
if __name__=="__main__":
    # jy("Sell",6749,5)
    # jy("Sell", 53, 2)
    # jy("Sell", 53, 10)
    # jy("Sell", 52, 2)
    # jy("Sell", 52, 1)

    jy("Buy", 53, 5)
    jy("Buy", 53, 2)
    jy("Buy", 53, 10)
    jy("Buy", 52, 2)
    jy("Buy", 52, 1)


